package org.apache.flink;

import org.apache.flink.endpoint.JobManagerRpcEndpoint;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.runtime.rpc.RpcService;
import org.apache.flink.runtime.rpc.RpcSystem;

public class JobManager {


    public static void main(String[] args) throws Exception {
        System.out.println("JobManager start...");

        Configuration configuration = new Configuration();
        RpcSystem rpcSystem = RpcSystem.load(configuration);
        RpcService rpcService = rpcSystem.remoteServiceBuilder(configuration, "127.0.0.1", "9001")
                .createAndStart();


        JobManagerRpcEndpoint jobManagerRpcEndpoint = new JobManagerRpcEndpoint(rpcService, "jm");
        jobManagerRpcEndpoint.start();

    }

}
